/**
 * 
 */
package cn.nawang.ebeim.client;

import cn.nawang.ebeim.client.bean.BreakPointQueue;
import cn.nawang.ebeim.client.bean.TaskStatusBean;
import cn.nawang.ebeim.client.util.DbUtil;
import cn.nawang.ebeim.client.util.DealUnfinishTask;

/**
 * @ClassName: BreakPointThread
 * @Description: 断点续传线程
 * @author zhangjf
 * @date 2015年12月1日 下午6:50:12
 * @version v1.0
 */
public class BreakPointThread implements Runnable{

  @Override
  public void run() {
    while(true){
      try {
        TaskStatusBean taskStatusBean = BreakPointQueue.dequeue();
        if (taskStatusBean.getType() == DbUtil.TASK_TYPE_FILE) {
          new DealUnfinishTask().uploadDataFile(taskStatusBean);
        } else if (taskStatusBean.getType() == DbUtil.TASK_TYPE_VERSION) {
          new DealUnfinishTask().uploadVersionFile(taskStatusBean);
        }
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      
    }
    
  }

  
}
